package cn.org.intelli.zjgflink.entity;


import lombok.Data;

import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.Id;
import java.util.Date;

@Entity(name = "flinkJob")
@Data
public class FlinkJobEntity {
    @Id
    private String flinkJobId;

    @Column
    private String flinkJobName;

    @Column
    private Integer slotNumber;

    @Column
    private String mainFunction;

    @Column
    private String jarFileName;

    @Column
    private String savePointPath;

    @Column
    private String taskManagerProcessSize;

    @Column
    private String jobManagerProcessSize;

    @Column
    private Integer parallelism;

    @Column(columnDefinition = "text")
    private String argsStr;

    @Column(columnDefinition = "text")
    private String description;

    @Column(columnDefinition = "text")
    private String deployMessage;

    @Column
    private String yarnApplicationId;

    @Column
    private Date deployTime;

    @Column
    private String status;

    @Column
    private Date createTime;

    @Column
    private Date updateTime;

    @Column
    private String userPin;
}
